package com.boarsoft.message.rocketmq.converter;

import com.boarsoft.message.bean.Message;

public interface RocketMsgConverter {
	/**
	 * 
	 * @param session
	 * @param m
	 * @return
	 * @throws Exception 
	 */
	org.apache.rocketmq.common.message.Message convert(Message m) throws Exception;

	/**
	 * 
	 * @param m
	 * @return
	 * @throws Exception 
	 */
	Message convert(org.apache.rocketmq.common.message.Message m) throws Exception;
}
